package com.lx.tool;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;

/**
 * 数据库连接工具类
 */
public class SqlInit {
    Connection connection;
    Statement statement;

    private SqlInit(){

        try {
            //1、通过全类名以反射的形式加载数据库的驱动
            Class.forName("com.mysql.jdbc.Driver");
            //2、设置数据库的连接路径
            String url="jdbc:mysql://localhost:3306/file";
            //3、设置数据库的账号和密码
            String user="root";
            String password="123456";
            //4、获取数据库的连接对象
            connection= DriverManager.getConnection(url,user,password);
            System.out.println("数据库连接成功！！");
        } catch (Exception e) {
            e.printStackTrace();
        }

    }
    //创建获取连接的方法
    public Connection getConnection(){
        return connection;
    }
    //编写预处理sql语句的方法
    public Statement getStatement(){
        try {
            statement=connection.createStatement();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return statement;
    }
    //创建一个工厂方法
    public static SqlInit build(){
        SqlInit sqlInit=new SqlInit();
        return sqlInit;
    }
}
